package com.hdaccp.beike

import org.apache.spark.sql.SparkSession

/**
  * spark读取的默认文件格式
  */
object Demo5 {
  def main(args: Array[String]): Unit = {
    //1.
    val spark = SparkSession.builder()
      .appName("beikeDemo5App")
      .master("local[2]")
      .getOrCreate()
    import spark.implicits._
    val dataFrame = spark.read.load("f:/resources/users.parquet")

    dataFrame.show()


    spark.stop()
  }
}
